package com.gagakuai.app.flink;

import com.gagakuai.app.flink.watermark.IndexTimestampAssigner;
import com.gagakuai.domain.facts.Fact;
import com.gagakuai.infrastructure.utils.FlinkUtils;
import com.gagakuai.infrastructure.utils.ParameterConstantsUtil;
import com.gagakuai.infrastructure.utils.ParameterUtils;
import org.apache.flink.api.common.eventtime.WatermarkStrategy;
import org.apache.flink.api.java.operators.DataSource;
import org.apache.flink.api.java.utils.ParameterTool;
import org.apache.flink.streaming.api.datastream.DataStreamSource;

import java.time.Duration;
import java.util.Set;

/**
 * @description: index 通用计算
 * @author: houhong
 * @create: 2024-09-07 19:14
 **/
public class GeneraMeticJob {


    public static void executeIndexCalculate(Set<Fact<?>> factSet) {

        ParameterTool tool = ParameterUtils.getParameters();

        DataSource<Fact<?>> dataSource = FlinkUtils.BATCH_ENV
                .fromCollection(factSet);

    }


}
